package android.slc.rx;

import io.reactivex.rxjava3.annotations.NonNull;
import io.reactivex.rxjava3.core.FlowableSubscriber;
import org.reactivestreams.Subscription;

public class SimpleFlowableSubscriber<T> implements FlowableSubscriber<T> {
    protected Subscription subscription;

    @Override
    public void onSubscribe(@NonNull Subscription subscription) {
        this.subscription = subscription;
    }

    @Override
    public void onNext(T t) {

    }

    @Override
    public void onError(Throwable throwable) {

    }

    @Override
    public void onComplete() {

    }

    protected void requestOne(){
        this.subscription.request(1);
    }
}
